package com.gitee.xhs;

import com.gitee.xhs.sampleRecod.transactionRecord.TransactionIterator;
import com.gitee.xhs.sampleRecod.transactionRecord.jmockTool.TransactionLoopOneToFiveMockerInterceptor;
import com.gitee.xhs.sampleSource.TransactionBoundOneSecondSource;
import com.gitee.xhs.sourceIterator.RateLimitedIterator;

/**
 * @author BigHead
 * @date 2022/7/14 16:19
 * @description WatermarkSourceFactory
 */
public class WatermarkSourceFactory {

    public static TransactionBoundOneSecondSource defaultTransactionBoundOneSecondSource() {
        return new TransactionBoundOneSecondSource(
                new RateLimitedIterator<>(
                        new TransactionIterator(
                                true,
                                new TransactionLoopOneToFiveMockerInterceptor(),
                                null,
                                null,
                                null,
                                true
                        )
                )
        );
    }

}
